package com.xbai.spark.sql

import org.apache.spark.SparkConf
import org.apache.spark.sql.{DataFrame, SparkSession}

/**
  * spark sql
  * @author xbai
  * @Date 2021/1/5
  */
object SparkSQL02_SQL {

  def main(args: Array[String]): Unit = {
    // 创建配置对象
    val conf: SparkConf = new SparkConf().setMaster("local[*]").setAppName("sql")
    // 创建 SparkSQL 的环境对象
    val spark: SparkSession = SparkSession.builder().config(conf).getOrCreate()

    // 读取数据，构建 DataFrame
    val df: DataFrame = spark.read.json("in/user.json")

    // 将 DataFrame 转换位一张表
    df.createOrReplaceTempView("people")
    // 采用 sql 的语法访问数据
    spark.sql("select * from people").show()

    spark.stop()
  }
}
